package com.jlu.yygh.receiver;

import com.jlu.rabbit.constant.MqConst;
import com.jlu.yygh.service.MsmService;
import com.jlu.yygh.vo.msm.MsmVo;
import com.rabbitmq.client.AMQP;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

//@Component
//public class MsmReceiver {
//  @Autowired
//  private MsmService msmService;
//  @RabbitListener(bindings = @QueueBinding(
//          value = @Queue(value = MqConst.QUEUE_MSM_ITEM, durable = "true"),
//          exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_MSM),
//          key = {MqConst.ROUTING_MSM_ITEM}
//  ))
//  public void send(MsmVo msmVo, Message message, AMQP.Channel channel) {
//    msmService.send(msmVo);
//  }
//}
